package com.ma.common.mq;

import java.util.List;

/**
 * redis 队列消费者抽象者
 * @param <T>
 */
public abstract class RedisMQConsumer<T> {
    /**
     * 消费者消费消息回调
     */
    public void onMessage(T data){}
    /**
     * 消费者消费消息回调
     */
    public void onMessage(List<T> datas){}
    /**
     * 生成redis队列完整key
     */
    public String generateKey(){
        //默认队列名称就是redis的key
        RedisMQListener annotation = this.getClass().getAnnotation(RedisMQListener.class);
        return annotation.queue();
    }
    /**
     * 队列是否就绪。返回true才会开始消费
     */
    public Boolean isReady(){
        return true;
    }
}
